package com.boarsoft.boar.message.service.impl;

import com.boarsoft.boar.message.biz.TargetQueueBiz;
import com.boarsoft.boar.message.entity.TargetQueueEntity;
import org.springframework.beans.factory.annotation.Autowired;

public class TargetQueueMonitorImpl extends AbstractQueueMonitorImpl {
	@Autowired
	protected TargetQueueBiz targetQueueBiz;

	public TargetQueueMonitorImpl(){
		type = "target";
	}

	protected Object gather(String queueId) {
		TargetQueueEntity tq =targetQueueBiz.get(queueId);
		return brokerAdapter.getMessageBroker(tq.getBroker()).statTargetQueue(tq.getCode());
	}
}
